package org.geeks.gsjetcache.func;

import org.geeks.gsjetcache.GsJetcacheApplicationTests;
import org.geeks.gsjetcache.constant.JetcachePurge;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;

import io.lettuce.core.RedisClient;

public class RedisPubT extends GsJetcacheApplicationTests {

	@Autowired
	private RedisClient defaultClient;

	@Test
	public void publish() {
		String message = "byId:1";

		defaultClient.connect().async().publish(JetcachePurge.CHANNEL, message);
	}
}
